package com.qf.flinketl.service;

import com.alibaba.fastjson2.JSONObject;
import com.qf.flinketl.protobuf.MessageRowOuterClass;
import com.qf.flinketl.vo.UserRelationVO;
import java.io.Serializable;
import java.util.List;
import java.util.Map;

/**
 * @Description: @Author: KyrieFc @Date: 2023/10/24
 */
public interface AbstractCommonMetaService extends Serializable {
  Map<String, Object> parse(String key, byte[] msg, String dataName) throws Exception;

  Map<String, Object> parse(String key, String msg, String dataName) throws Exception;

  Map<String, Object> filter(Map<String, Object> parsedMap) throws Exception;

  List<MessageRowOuterClass> map(Map<String, Object> parsedMap) throws Exception;

  void saveValues(MessageRowOuterClass messageRowOuterClass) throws Exception;

  UserRelationVO getUserRelationVo(MessageRowOuterClass msgRow) throws Exception;

  boolean isValidMsg(JSONObject json);
}
